﻿//-------------------------------------------------------------------------
///-----------------mqtt_session-------------------------------------------
///-----------------mqtt通讯会话类-----------------------------------------
///-----------------2022/3/28---by mky.蒙克雨------------------------------
//-------------------------------------------------------------------------
#include "mqtt_session.h"
//-------------------------------------------------------------------------
#include <memory>
//-------------------------------------------------------------------------
mky::mqttSession::mqttSession() {
	//DebugL;
}

//-------------------------------------------------------------------------
mky::mqttSession::~mqttSession() {
	//DebugL;
}
static int unum = 0;
//-------------------------------------------------------------------------
void mky::mqttSession::onRecvMsg(void* client, std::string topic, std::string recv_messageg) {
	unum++;
	std::cout << "-----------------------"  << std::endl;
	std::cout << "unum: ["<<unum << "]" << std::endl;
	std::cout << "-----------------------" << std::endl;
	//std::cout << "-----------------------" << topic << std::endl;
	//std::cout <<" topic        : " << topic << std::endl;
	//std::cout <<" recv_messageg: " << recv_messageg << std::endl;
	//toolkit::NoticeCenter::Instance().emitEvent("mqtt_recv_msg", client, topic.substr(topic_head_len), recv_messageg);
}

//-------------------------------------------------------------------------
